package drds.binlog.parse.mysql;

import com.lmax.disruptor.EventFactory;
import drds.binlog.common.Authors;
import drds.common.Author;
import lombok.Getter;
import lombok.Setter;

@Author(name = Authors.LI_YANG)
class MessageEventFactory implements EventFactory<MessageEvent>
{

    @Setter
    @Getter
    private MultiStageCoprocessor multiStageCoprocessor;

    public MessageEventFactory(MultiStageCoprocessor multiStageCoprocessor)
    {
        this.multiStageCoprocessor = multiStageCoprocessor;
    }

    public MessageEvent newInstance()
    {
        return new MessageEvent();
    }
}
